package com.sld.integrate.config;

import com.sld.integrate.service.IRecDevCalculateService;
import com.sld.integrate.utils.MessageQueueTaskManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.RedisTemplate;

import javax.annotation.Resource;

/**
 * 描述: 单机版队列管理配置类
 *
 * @Author tanli
 * @create 2022-05-04 11:48
 */
@Configuration
public class MessageQueueConfiguration {

    @Resource
    RedisTemplate redisTemplate;

    @Resource
    IRecDevCalculateService calculateService;

    @Bean
    public MessageQueueTaskManager getMessageQueueTaskManager() {
        return new MessageQueueTaskManager(redisTemplate, calculateService);
    }

}
